from celery import Celery


#进行Celery允许配置
# 为celery使用django配置文件进行设置
import os
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'mall.settings'


# 创建celery对象,第一个参数main习惯上给他设置为脚本路径
app = Celery(main='celery_tasks')


# 设置broker
app.config_from_object('celery_tasks.config')


# 需要celery自动检测该任务,里面的任务是通过脚本路径来实现的
app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.email', 'celery_tasks.html'])


# 命令行执行任务
# celery -A celery_tasks.main worker -l info